package cloud.xiguapi.ubas.analysis.hotpages.model;

import cloud.xiguapi.ubas.model.ApacheLogEvent;
import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
import org.apache.flink.streaming.api.windowing.time.Time;

/**
 * @author 大大大西西瓜皮🍉
 * date: 2021-5-18 下午 10:39
 * desc:
 */
public class HotPagesBoundedOutOfOrdernessTimestampExtractor
        extends BoundedOutOfOrdernessTimestampExtractor<ApacheLogEvent> {

    public HotPagesBoundedOutOfOrdernessTimestampExtractor(Time maxOutOfOrderness) {
        super(maxOutOfOrderness);
    }

    @Override
    public long extractTimestamp(ApacheLogEvent element) {
        return element.getTimestamp();
    }
}
